package com.yan.config;

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


/**
 * TODO
 *
 * @Author: 汪焰
 * @Date: 2021/7/5 23:32
 */
@Configuration
public class RabbitConfig {

    //Queue
    @Bean
    public Queue queue() {
        Queue queue = QueueBuilder.nonDurable("queue.boot.name.yan").build();
        return queue;
    }

}
